type go.pact.im/x/supervisor.managedProcess
9 uses
go.pact.im/x/supervisor (current package)
startstop.go#L47: m.processes.Range(func(pk K, _ *managedProcess[P]) bool {
supervisor.go#L26: processes syncx.Map[K, *managedProcess[P]]
supervisor.go#L48: type managedProcess[P process.Runnable] struct {
supervisor.go#L129: func (m *Supervisor[K, P]) startProcessForKey(ctx context.Context, pk K) (*managedProcess[P], error) {
supervisor.go#L149: func (m *Supervisor[K, P]) startProcess(ctx context.Context, pk K, r P) (*managedProcess[P], error) {
supervisor.go#L164: func (m *Supervisor[K, P]) startProcessUnlocked(ctx context.Context, pk K, r P) (*managedProcess[P], error) {
supervisor.go#L165: p := &managedProcess[P]{
supervisor.go#L181: func (m *Supervisor[K, P]) watchdog(pk K, p *managedProcess[P]) {
supervisor.go#L216: m.processes.Range(func(pk K, _ *managedProcess[P]) bool {